type golang.org/x/net/http2.serverConn
78 uses
golang.org/x/net/http2 (current package)
server.go#L80: testHookGetServerConn func(*serverConn)
server.go#L82: testHookOnPanic func(sc *serverConn, panicVal interface{}) (rePanic bool)
server.go#L211: activeConns map[*serverConn]struct{}
server.go#L214: func (s *serverInternalState) registerConn(sc *serverConn) {
server.go#L223: func (s *serverInternalState) unregisterConn(sc *serverConn) {
server.go#L255: conf.state = &serverInternalState{activeConns: make(map[*serverConn]struct{})}
server.go#L405: sc := &serverConn{
server.go#L543: func (sc *serverConn) rejectConn(err ErrCode, debug string) {
server.go#L551: type serverConn struct {
server.go#L610: func (sc *serverConn) maxHeaderListSize() uint32 {
server.go#L622: func (sc *serverConn) curOpenStreams() uint32 {
server.go#L636: sc *serverConn
server.go#L660: func (sc *serverConn) Framer() *Framer { return sc.framer }
server.go#L661: func (sc *serverConn) CloseConn() error { return sc.conn.Close() }
server.go#L662: func (sc *serverConn) Flush() error { return sc.bw.Flush() }
server.go#L663: func (sc *serverConn) HeaderEncoder() (*hpack.Encoder, *bytes.Buffer) {
server.go#L667: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L694: func (sc *serverConn) setConnState(state http.ConnState) {
server.go#L700: func (sc *serverConn) vlogf(format string, args ...interface{}) {
server.go#L706: func (sc *serverConn) logf(format string, args ...interface{}) {
server.go#L758: func (sc *serverConn) condlogf(err error, format string, args ...interface{}) {
server.go#L777: func (sc *serverConn) canonicalHeader(v string) string {
server.go#L814: func (sc *serverConn) readFrames() {
server.go#L846: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L856: func (sc *serverConn) closeAllStreamsOnConnClose() {
server.go#L863: func (sc *serverConn) stopShutdownTimer() {
server.go#L870: func (sc *serverConn) notePanic() {
server.go#L885: func (sc *serverConn) serve() {
server.go#L989: case func(*serverConn):
server.go#L1015: func (sc *serverConn) awaitGracefulShutdown(sharedCh <-chan struct{}, privateCh chan struct{}) {
server.go#L1033: func (sc *serverConn) onSettingsTimer() { sc.sendServeMsg(settingsTimerMsg) }
server.go#L1034: func (sc *serverConn) onIdleTimer() { sc.sendServeMsg(idleTimerMsg) }
server.go#L1035: func (sc *serverConn) onShutdownTimer() { sc.sendServeMsg(shutdownTimerMsg) }
server.go#L1037: func (sc *serverConn) sendServeMsg(msg interface{}) {
server.go#L1050: func (sc *serverConn) readPreface() error {
server.go#L1091: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1138: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1158: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1222: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1279: func (sc *serverConn) wroteFrame(res frameWriteResult) {
server.go#L1343: func (sc *serverConn) scheduleFrameWrite() {
server.go#L1391: func (sc *serverConn) startGracefulShutdown() {
server.go#L1414: func (sc *serverConn) startGracefulShutdownInternal() {
server.go#L1418: func (sc *serverConn) goAway(code ErrCode) {
server.go#L1432: func (sc *serverConn) shutDownIn(d time.Duration) {
server.go#L1437: func (sc *serverConn) resetStream(se StreamError) {
server.go#L1448: func (sc *serverConn) processFrameFromReader(res readFrameResult) bool {
server.go#L1500: func (sc *serverConn) processFrame(f Frame) error {
server.go#L1553: func (sc *serverConn) processPing(f *PingFrame) error {
server.go#L1572: func (sc *serverConn) processWindowUpdate(f *WindowUpdateFrame) error {
server.go#L1604: func (sc *serverConn) processResetStream(f *RSTStreamFrame) error {
server.go#L1623: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1669: func (sc *serverConn) processSettings(f *SettingsFrame) error {
server.go#L1697: func (sc *serverConn) processSetting(s Setting) error {
server.go#L1729: func (sc *serverConn) processSettingInitialWindowSize(val uint32) error {
server.go#L1757: func (sc *serverConn) processData(f *DataFrame) error {
server.go#L1851: func (sc *serverConn) processGoAway(f *GoAwayFrame) error {
server.go#L1915: func (sc *serverConn) processHeaders(f *MetaHeadersFrame) error {
server.go#L2029: func (sc *serverConn) upgradeRequest(req *http.Request) {
server.go#L2079: func (sc *serverConn) checkPriority(streamID uint32, p PriorityParam) error {
server.go#L2090: func (sc *serverConn) processPriority(f *PriorityFrame) error {
server.go#L2098: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L2134: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2199: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp requestParam) (*responseWriter, *http.Request, error) {
server.go#L2274: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2287: func (sc *serverConn) runHandler(rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) {
server.go#L2327: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2359: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2376: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2386: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2397: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2402: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2426: conn *serverConn
server.go#L2482: conn *serverConn
server.go#L2716: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L2742: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L3069: func (sc *serverConn) startPush(msg *startPushRequest) {
server.go#L3212: func (sc *serverConn) countError(name string, err error) error {